package com.hc.rabbit;

import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController

public class MQController {//如果为我们模拟发微博，那么这个控制器就应该叫WeiboController
    @Autowired
    AmqpTemplate amqpTemplate;
    @RequestMapping("/sendWeibo")
    public String sendWeibo(){
        String[] mails={"yangyi@qq.com","yangmi@qq.com","tangsan@qq.com"};
        for (String mail:mails){
            //为了避免发送邮件的程序拖垮当前发微博的功能，把发送邮件的任务踢出去
            //所以我们需要告诉对方程序要发给哪些人
            amqpTemplate.convertAndSend("mail_queue",mail+"|亲爱的小粉，我刚刚发了微博--这次听点一样的--快来围观吧");
        }

        return "send success";
    }
}
